package com.oig.sys.msg.service;

import com.oig.sys.msg.dto.MqMsgDto;
import com.oig.sys.msg.entity.TbMqMsg;
import com.oig.sys.msg.vo.MqMsgVo;

import java.util.List;

/**
 * @author wuxl
 */
public interface ITbMqMsgService {

	/**
	 * add
	 */
	MqMsgVo addMqMsg(MqMsgDto mqMsgDto);

	TbMqMsg getMqMsg(Integer id);

	List<TbMqMsg> findAllUnReadyMsg();
	List<TbMqMsg> findAllUnSendMqMsg();

	void updateMsgError(TbMqMsg mqMsg);

	void updateMsgReady(TbMqMsg mqMsg);



	void moveMsgToHis(TbMqMsg mqMsg);

}
